package com.szjz.rabbitmq.client.direct;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.szjz.rabbitmq.client.util.RabbitMQUtils;
import lombok.extern.slf4j.Slf4j;

import java.io.IOException;

/**
 * @author 史博
 * @desc 消息提供者
 * @date 2020/8/25 4:56 下午 周二
 */
@Slf4j
public class Provider1 {

    public static void main(String[] args) throws IOException {
        // 创建连接和通道
        Connection connection = RabbitMQUtils.getConnection();
        Channel channel = connection.createChannel();
        // 声明交换机
        // 参数1：交换机名称
        // 参数2：交换机类型
        channel.exchangeDeclare("logs_direct", "direct");
        //发送消息
        String routingKey = "info";
        channel.basicPublish("logs_direct", routingKey, null, ("基于direct类型, routingKey=" + routingKey + "交换机").getBytes());
        RabbitMQUtils.close(connection, channel);
    }
}
